//package com.cjl.demo.thread;
//
//import java.util.HashSet;
//import java.util.Set;
//
///**
// * <p>Copyright: All Rights Reserved</p>
// * <p>Description: </p>
// *
// * @ uthor chenjinliang
// * @ date: 2020/2/23
// */
//public class ThreadPoolTest {
//    public static void main(String[] args) {
//        Set<Integer> totalUserSet = new HashSet<>();
//        for(int i =0 ; i <1000000 ; i++){
//            totalUserSet.add(i);
//        }
//        //遍历总的用户集，如果有未读，发送esb消息
//        for(Integer touserid: totalUserSet){
//            System.out.println("touserid =" + touserid);
//            try {
//                TaskExecuteHelper.filterUnReaderMsgJob_executor.execute(new MyThread(touserid));
//            } catch (Exception e) {
//                e.printStackTrace();
//                System.out.println("filterUnReaderMsgJob_executor exception, e =" + e.getMessage());
//            }
//        }
//    }
//
//}
